package top.reminis.task;

import lombok.extern.slf4j.Slf4j;
import top.reminis.flink.UniversalFlinkJob;

/**
 * 库存数据处理Flink作业
 * 专门处理库存数据的ETL任务
 * 
 * @author zwf
 * @create 2025-09-24
 */
@Slf4j
public class RepertoryFlinkJob {

    private static final String CONFIG_FILE = "mes-repertory.yaml";

    public static void main(String[] args) {
        log.info("=== 启动库存数据处理作业 ===");
        log.info("配置文件: {}", CONFIG_FILE);
        
        // 调用通用Flink作业框架
        UniversalFlinkJob.main(new String[]{CONFIG_FILE});
    }
}
